8497f13baa0467eada1b806d7c7ac522a023d255,iep-rxhttp/src/test/java/com/netflix/iep/http/RxHttpTest.java,RxHttpTest,simplePost,#,536
Before Change
return res.getContent();
}
})
.toBlocking()
.forEach(new Action1<ByteBuf>() {
@Override
public void call(ByteBuf byteBuf) {
builder.append(byteBuf.toString(Charset.defaultCharset()));
}
});
Assert.assertEquals("foo bar", builder.toString());
After Change
Assert.assertEquals(200, res.getStatus().code());
return res.getContent();
})
.toBlocking()
.forEach(byteBuf -> builder.append(byteBuf.toString(Charset.defaultCharset())));
Assert.assertEquals("foo bar", builder.toString());